//package concurrent.no11;
//
//import com.sun.xml.internal.ws.api.message.Packet;
//
//import java.util.Arrays;
//import java.util.List;
//import java.util.stream.Collectors;
//
///**
// * 〈一句话功能简述〉<br>
// * 〈〉
// *
// * @author dan shouyang
// * @create 2021/3/12
// * @since 1.0.0
// */
//public class MutilTest {
//    /**
//     * 均衡获取一个子队列。
//     *
//     * @return
//     */
//    public BlockingQueue<Message> getSubQueue() {
//        int errorCount = 0;
//        for (; ; ) {
//            if (subMsgQueues.isEmpty()) {
//                return null;
//            }
//            int index = (int) (System.nanoTime() % subMsgQueues.size());
//            try {
//                return subMsgQueues.get(index);
//            } catch (Exception e) {
//                // 出现错误表示，在获取队列大小之后，队列进行了一次删除操作
//                LOGGER.error("获取子队列出现错误", e);
//                if ((++errorCount) < 3) {
//                    continue;
//                }
//            }
//        }
//    }
//
//
//    /**
//     * 使用的时候，只需要往总队列里发消息。
//     */
//    public void get() {
//        // 往消息队列里添加一条消息
//        IMsgQueue messageQueue = MsgQueueFactory.getMessageQueue();
//        Packet msg = Packet.createPacket(Packet64FrameType.TYPE_DATA, "{}".getBytes(), (short) 1);
//        messageQueue.put(msg);
//    }
//}
